c93d7cf48379ca95d65303de73d52a20fdf541a8,src/main/java/io/vertx/ext/asyncsql/impl/AsyncSQLConnectionImpl.java,AsyncSQLConnectionImpl,query,#String#Handler#,60

Before Change



  @Override
  public SQLConnection query(String sql, Handler<AsyncResult<ResultSet>> handler) {
    beginTransactionIfNeeded().flatMap((res) -> {
      connection.sendQuery(sql);
    }).onComplete(done(handler, queryResultToUpdateResult));

    return this;
  }

After Change



  @Override
  public SQLConnection query(String sql, Handler<AsyncResult<ResultSet>> handler) {
    beginTransactionIfNeeded().setHandler(v -> {
      final scala.concurrent.Future<QueryResult> future = connection.sendQuery(sql);
      future.onComplete(ScalaUtils.<QueryResult>toFunction1(ar -> {
        if (ar.succeeded()) {
          handler.handle(Future.succeededFuture(queryResultToResultSet(ar.result())));
        } else {
          handler.handle(Future.failedFuture(ar.cause()));
        }

      }),executionContext);
    });

    return this;
  }